2e5c207f9fa772ee0bd6337260e22eb6d2d77413,storio-sqlite/src/main/java/com/pushtorefresh/storio/sqlite/operations/get/PreparedGetObject.java,PreparedGetObject,asRxObservable,#,161
Before Change
}
if (!tables.isEmpty()) {
return storIOSQLite
.observeChangesInTables(tables) // each change triggers executeAsBlocking
.map(MapSomethingToExecuteAsBlocking.newInstance(this))
.startWith(Observable.create(OnSubscribeExecuteAsBlocking.newInstance(this))) // start stream with first query result
.onBackpressureLatest()
.subscribeOn(Schedulers.io());
} else {
return Observable
.create(OnSubscribeExecuteAsBlocking.newInstance(this))
.subscribeOn(Schedulers.io());
}
}
After Change
final Observable<T> observable;
if (!tables.isEmpty()) {
observable = storIOSQLite
.observeChangesInTables(tables) // each change triggers executeAsBlocking
.map(MapSomethingToExecuteAsBlocking.newInstance(this))
.startWith(Observable.create(OnSubscribeExecuteAsBlocking.newInstance(this))) // start stream with first query result
.onBackpressureLatest();
} else {
observable = Observable.create(OnSubscribeExecuteAsBlocking.newInstance(this));
}
return RxJavaUtils.subscribeOn(storIOSQLite, observable);
}
/**